package com.zhss.service;

import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

/**
 * @author : peigen
 * Date: 2021/7/5 上午9:21
 */
@Component
public class MessageListener {
    @StreamListener("my-test-queue")
    public void receive(byte[] message) {
        System.out.println("接收到的消息是：" + new String(message));
    }
}
